package com.kt.mes.listener;

import com.kt.mes.util.WebSocketServer;
import org.eclipse.milo.opcua.sdk.client.SessionActivityListener;
import org.eclipse.milo.opcua.sdk.client.api.UaSession;

import java.io.IOException;


public class OpcSessionActivityListener implements SessionActivityListener {

    public void onSessionActive(UaSession session){

       // System.out.println("建立连接-----"+session.getSessionName());
        if(session.getSessionName().contains("gw01")){
            System.out.println("gw01 重新连接");
        }
        if(session.getSessionName().contains("gw02")){
            System.out.println("gw02 重新连接");
        }
        if(session.getSessionName().contains("gw03")){
            System.out.println("gw03 重新连接");
        }
        if(session.getSessionName().contains("gw04")){
            System.out.println("gw04 重新连接");
        }
        if(session.getSessionName().contains("gw05")){
            System.out.println("gw05 重新连接");
        }
        if(session.getSessionName().contains("gw06")){
            System.out.println("gw06 重新连接");
        }
        try {
            //发送至页面
            WebSocketServer.sendInfo("refresh", "state_page");
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    public  void onSessionInactive(UaSession session) {
       // System.out.println("断开连接-----"+session.getSessionName());

        if(session.getSessionName().contains("gw01")){
            System.out.println("gw01 断开连接");
        }
        if(session.getSessionName().contains("gw02")){
            System.out.println("gw02 断开连接");
        }
        if(session.getSessionName().contains("gw03")){
            System.out.println("gw03 断开连接");
        }
        if(session.getSessionName().contains("gw04")){
            System.out.println("gw04 断开连接");
        }
        if(session.getSessionName().contains("gw05")){
            System.out.println("gw05 断开连接");
        }
        if(session.getSessionName().contains("gw06")){
            System.out.println("gw06 断开连接");
        }
        try {
            //发送至页面
            WebSocketServer.sendInfo("refresh", "state_page");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }




}
